package com.custom.source;

import java.io.Serializable;
import java.util.Collection;

/**
 * 枚举分片保存点类
 * <p>
 * 需要是可序列化的
 *
 * @param <SplitT> 分片类型
 */
public abstract class ClinkEnumCheckpoint<SplitT extends ClinkSourceSplit> implements Serializable {

    public Collection<SplitT> state;

    public ClinkEnumCheckpoint(Collection<SplitT> state) {
        this.state = state;
    }

    public Collection<SplitT> getState() {
        return state;
    }
}
